package com.ydl.learning.flink.demo.transformations

import com.ydl.learning.flink.demo.Utils
import org.apache.flink.api.scala._

/**
 *
 *
 * @author ydl
 * @since 2020/10/10
 */
object MinByAndMaxByDemo extends App with Utils {
  val input: DataSet[(Int, String, Double)] = env.fromCollection(dataDemo)

}
